package com.whynot.frame.manythread.flowline;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

import com.whynot.frame.manythread.flowline.entities.Msg;

public class Multiply implements Runnable {
	public static BlockingDeque<Msg> qDeque = new LinkedBlockingDeque<Msg>();

	public void run() {
		try {
			while(true){
				Msg msg = qDeque.take();
				msg.j = msg.j * msg.i;
				//Multiply流行线程完后后，Div开启
				Div.qDeque.add(msg);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

	}

}
